package com.imooc.ecommerce.stream.qinyi;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

/**
 * 自定义输入信道
 * @author zhangshao
 * @since 2023/12/10 23:11
 */
public interface QinyiSink {

    String INPUT = "qinyiInput";

    /**
     * 输入信道名称是 qinyiInput,需要使用Stream 绑定器在 yml文件中配置
     */
    @Input(QinyiSink.INPUT)
    SubscribableChannel qinyiInput();
}
